
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName("word_seg Test").enableHiveSupport().getOrCreate()
df= spark.sql("select * from  dtsw_pro.cfg_town;")
df.show(10)
spark.stop()